package com.apex.spark.structuredstream;

import com.apex.spark.SparkBaseSink;
import com.apex.spark.SparkEnvironment;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.streaming.StreamingQueryException;

public interface SparkStructuredStreamingSink extends SparkBaseSink {
    void outputStructuredStreaming(SparkEnvironment env, Dataset<Row> inDataSet);
}
